package mysql

import (
	"gitee.com/worklz/yunj-blog-go-micro-common/log"
)

// 关闭数据库连接
func CloseDb() {
	if DB == nil {
		return
	}
	sqlDB, err := DB.DB()
	if err != nil {
		log.Error("获取数据库底层sql.DB对象失败", err)
		return
	}
	if err := sqlDB.Close(); err != nil {
		log.Error("关闭数据库连接失败", err)
		return
	}
	log.Info("关闭数据库连接成功")
}
